import pymysql

class sqlconnect:
  def sqljudje(sql):
    # 建立数据库连接
    data = {
      'host': '172.16.1.20',
      'user': 'root',
      'password': 'GST.2021',
      'db': 'gst_broadcast',
      'charset': 'utf8mb4'
    }

    # 尝试连接
    try:
      connection = pymysql.connect(**data)
      #print("数据库连接成功！")
      # 接下来可以执行查询或其他操作...
    except pymysql.MySQLError as e:
      print(f"数据库连接失败: {e}")

    conn = pymysql.connect(**data)

    # 创建游标对象,用于去执行sql操作
    cursor = conn.cursor()
    # 执行 SQL 查询或操作

    cursor.execute(sql)  # 执行sql语句
    result = cursor.fetchall()  # 获取查询结果,result为元组tuple； 例：result[1][1]为字段对应值
    # print("打印输出结果类型",type(result))
    # print("result数据库类型：",type(result))
    return result



